/*
 Navicat Premium Data Transfer

 Source Server         : 192.168.2.45
 Source Server Type    : MySQL
 Source Server Version : 50651 (5.6.51-log)
 Source Host           : 192.168.2.45:3306
 Source Schema         : star

 Target Server Type    : MySQL
 Target Server Version : 50651 (5.6.51-log)
 File Encoding         : 65001

 Date: 08/11/2023 16:26:42
*/

SET NAMES utf8mb4;
SET FOREIGN_KEY_CHECKS = 0;

-- ----------------------------
-- Table structure for input_data_sources
-- ----------------------------
DROP TABLE IF EXISTS `input_data_sources`;
CREATE TABLE `input_data_sources` (
  `id` int(11) NOT NULL AUTO_INCREMENT,
  `source_name` varchar(255) NOT NULL COMMENT '表示要cdc的yutu库的名称，默认为mysql，是保存在数据库中',
  `source_table_name` varchar(255) NOT NULL COMMENT '要接入的cdc的mysql的数据库表名',
  `source_pk` varchar(2000) DEFAULT NULL COMMENT '接入的表的主键',
  `target_name` varchar(255) DEFAULT NULL COMMENT '落的starrock的库信息，默认为starrocks_server',
  `target_table_name` varchar(255) DEFAULT NULL,
  `target_pk` varchar(255) DEFAULT NULL COMMENT 'cdc落库的表名',
  `kafka` varchar(255) DEFAULT NULL COMMENT '接入后的kafka源，默认为kafka_input',
  `kafka_topic` varchar(255) DEFAULT NULL COMMENT '接入后发送的消息的topic名称',
  `kafka_pk` varchar(255) DEFAULT NULL COMMENT '写入的主键',
  `job_name` varchar(255) NOT NULL COMMENT '在集群制定任务名称',
  `create_time` varchar(30) NOT NULL,
  `update_time` varchar(30) NOT NULL,
  `is_delete` bigint(1) NOT NULL DEFAULT '0' COMMENT '1 是 0 否',
  `status` bigint(1) DEFAULT '2' COMMENT '状态 1，运行  2.停止',
  `task_type` varchar(255) DEFAULT NULL COMMENT '任务类型',
  `entry_class` varchar(255) DEFAULT NULL,
  `jobId` varchar(255) DEFAULT NULL,
  `arguments` text,
  `url` varchar(255) DEFAULT NULL COMMENT '路径',
  `data_source_id` int(11) DEFAULT NULL,
  `target_id` int(11) DEFAULT NULL,
  `kafka_target_id` int(11) DEFAULT NULL,
  `describes` varchar(255) DEFAULT NULL COMMENT '描述',
  PRIMARY KEY (`id`) USING BTREE,
  UNIQUE KEY `idx` (`job_name`) USING BTREE
) ENGINE=InnoDB AUTO_INCREMENT=10009 DEFAULT CHARSET=utf8;

-- ----------------------------
-- Records of input_data_sources
-- ----------------------------
BEGIN;
INSERT INTO `input_data_sources` (`id`, `source_name`, `source_table_name`, `source_pk`, `target_name`, `target_table_name`, `target_pk`, `kafka`, `kafka_topic`, `kafka_pk`, `job_name`, `create_time`, `update_time`, `is_delete`, `status`, `task_type`, `entry_class`, `jobId`, `arguments`, `url`, `data_source_id`, `target_id`, `kafka_target_id`, `describes`) VALUES (1, 'mysql', 'order_info,order_details,user_info,user_details', 'id;id;id;id', 'starrocks_server', 'order_info,oder_details,user_info,user_details', 'id;id;id;id', 'kafka_input', 'star_order_info_topic,star_order_details_topic,star_user_info_topic,star_user_details_topic', 'id;id;id;id', 'mysql-cdc-starrocks', '', '', 0, 2, NULL, NULL, NULL, NULL, NULL, 1, NULL, NULL, NULL);
COMMIT;

SET FOREIGN_KEY_CHECKS = 1;
